package neu.soft.binder;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface ChannelBinder {

    @Input("financial-supply-input")
    SubscribableChannel shortageInput();

    @Output("financial-supply-output")
    MessageChannel supplyOutput();

    @Input("financial-warehouse-input")
    SubscribableChannel warehouseInput();

    @Input("financial-receipt-input")
    SubscribableChannel warehouseOutputInput();

    @Input("financial-journal-input")
    SubscribableChannel journalInput();

    //监听客户支付，完成订单
    @Input("financial-pay-input")
    SubscribableChannel payInput();

    //模拟
    @Output("financial-mock-output")
    MessageChannel mockOutput();

}
